package com.heima.article.process;

import org.apache.kafka.streams.kstream.KStream;
import org.springframework.cloud.stream.annotation.Input;
import org.springframework.cloud.stream.annotation.Output;

public interface IHotArticleProcessor {

//声明源头和目标话题 接下来用在listener包下的HotArticleListener类里
    /**
     * 数据来源话题
     * @return
     */
    @Input("hot_article_score_topic")
    KStream<String, String> input();


    /**
     * 实时计算结果话题
     * @return
     */
    @Output("hot_article_result_topic")
    KStream<String, String> output();


}
